//package com.github.llyb120.driver.qiuya;
//
//import static com.github.llyb120.driver.qiuya.WebSocket.Action.CONNECT;
//import static com.github.llyb120.driver.qiuya.WebSocket.Action.SEND;
//
//public class WebSocketWriteHandler implements Runnable{
//
//    private WebSocket webSocket;
//
//    public WebSocketWriteHandler(WebSocket webSocket) {
//        this.webSocket = webSocket;
//    }
//
//    @Override
//        public void run() {
//
//            try {
//                did();
//            } catch (InterruptedException e) {
//                e.printStackTrace();
//            }
//        }
//
//        public void did() throws InterruptedException {
//            WebSocket.this.ws.connectBlocking();
//            while(true){
//                WebSocket.Action item = (WebSocket.Action) writeQueue.take();
//                if(item.order == CONNECT) {
//                    WebSocket.this.reconnect();
//                } else if(item.order == SEND) {
//                    if(!ws.isOpen()){
//                        writeQueue.put(new WebSocket.Action(CONNECT, null));
//                        writeQueue.put(item);
//                    } else {
//                        WebSocket.this.send(item);
//                    }
//                }
//            }
//
//        }
//}
